package com.tcs.test.kafka.customer;

import javax.annotation.Resource;

import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.tcs.test.BaseJunit4Test;

public class KafkaCustomerMain extends BaseJunit4Test {

	private final Logger logger = LoggerFactory.getLogger(KafkacustomerTest.class);
	
	private final Object lock = new Object();
	
	@Resource(name="kafkaConsumerService")
	private KafkacustomerTest kafkacustomerTest;
	
	@Test
	public void test1() {
		synchronized (lock) {
			try {
				lock.wait();
			} catch (InterruptedException e) {
				logger.error("" , e);
			}
		}
	}
}
